package ex.datastream.functions.function;

import ex.vo.Person;
import org.apache.flink.api.common.functions.FilterFunction;

public class FilterFunc implements FilterFunction<Person> {
    @Override
    public boolean filter(Person person) throws Exception {
        return person.age >= 18;
    }
}
